package com.reactor.operator;

import reactor.core.publisher.Flux;

public class Window {

	public static void main(String[] args) {
		//window 操作符的作用类似于 buffer，所不同的是 window 操作符是把当前流中的元素收集到另外的 Flux 序列中，因此返回值类型是 Flux<Flux<T>>。在代码清单 7 中，输出结果是 5 个UnicastProcessor 字符。
		//这是因为 window 操作符所产生的流中包含的是 UnicastProcessor 类的对象，而 UnicastProcessor 类的 toString 方法输出的就是 UnicastProcessor 字符。
		Flux.range(1, 100).window(20).subscribe(System.out::println);
	}

}
